package com.yuanian.timingwheel.threadpool;

import java.util.concurrent.*;

public class ThreadPoolExecutorFactory {

    public static LinkedBlockingQueue queue = new LinkedBlockingQueue<>(1000000);

    private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10,
            30,
            1000,
            TimeUnit.SECONDS,
            queue
    );

    public static ThreadPoolExecutor getThreadPool(){

        // 创建线程池
        return threadPoolExecutor;

    }
}
